package cn.tk.service.log.customer;

/**
 * Created by denglw on 2019/8/17.<br/>
 * Desc: 日志入库消费者基类
 */
public abstract class BaseCustomer<Q, S> implements Runnable {

    protected Q queue;
    protected S service;

    BaseCustomer(Q queue, S service) {
        this.queue = queue;
        this.service = service;
    }

    @Override
    public void run() {
        start();
    }

    /**
     * 日志入库消费处理逻辑
     */
    public abstract void start();
}
